<?php
ini_set('display_errors', 1);
$dir = dirname(dirname(__FILE__));
include($dir.'/__queue_global.php');


class ml_mq_extRelation_newExt extends MqClass{
    const QUEUE_NAME = ML_QUEUENAME_EXTFOLLOW_NEW;
    private $oBizExtFollow;
    
    public function __construct($queue)
    {
        $this->oBizExtFollow = new ml_biz_extRelation_extFollow();
        
        parent::__construct($queue);
    }    
    
    public function run_job(){
        //接收的数据
        $arr = $this->src_data;
        
        $meila_uid = trim($arr['meila_uid']);
        $trd_uid = trim($arr['3rd_uid']);
        $type_id = trim($arr['type_id']);
        $access_token = trim($arr['access_token']);
        
        if (empty($meila_uid) ||empty($type_id)||empty($type_id)) {
            return ;
        }
        
        $re = $this->oBizExtFollow->init_newExtFollow_redis($meila_uid, $trd_uid, $type_id,$access_token);


        
    }
    
    
}

$xblog_obj = new ml_mq_extRelation_newExt(new McQueue(ml_mq_extRelation_newExt::QUEUE_NAME));
$argv[1]   = __FILE__;
$xblog_obj->setArgv($argv[1]);
$xblog_obj->execute();